
redis = require "redis"
client = redis.connect('127.0.0.1', 6379)
local mid = 3
local mkey = "material:"..mid

local MTKey = "task:"..mid


print(client:get(mkey))
print(client:sismember(MTKey,1))

client:del(mkey)
client:del(MTKey)


--创建消费者组
--XGROUP CREATE steam.task t1 0 MKSTREAM
